package com.zhxy.util.message;


/**
 * 消息管道侦听器
 * @author 刘勉
 *
 */
public interface MessageServiceListener extends ConnectionListener<MessagePipe> {
	
	/**
	 * 收到一个消息
	 * @param pipe 连接的唯一标识
	 * @param message 消息
	 */
	void message(MessagePipe pipe, Object message);
	
	/**
	 * 需要发送心跳包
	 * @param pipe 连接的唯一标识
	 */
	void keepAlive(MessagePipe pipe);
}
